package D

import rx.Observable
import java.text.SimpleDateFormat
import java.util.*
import java.util.concurrent.TimeUnit


fun main(args: Array<String>) {

    val sdf = SimpleDateFormat("yyyy-MM-dd hh:mm:ss")
    /**
     * 当有订阅者时，才会创建Observable。这样获取的数据是最新的
     */

    println(sdf.format(Date()))
    Thread.sleep(1000)

    var defer = Observable.defer({
        Observable.just(sdf.format(System.currentTimeMillis()))
    })

    defer.subscribe({
        println(it)
    })
}